草庐IT

Rust 并发编程

全部标签

go - 实现并发的失败尝试

我很难让go并发正常工作。我正在处理从XML数据源加载的数据。将数据加载到内存后,我循环遍历XML元素并执行操作。加并发前的代码已经过测试,可以正常使用,我认为不会对加并发有任何影响。我有2次失败的并发实现尝试,两次都具有不同的输出。我使用锁定是因为我不想进入竞争状态。对于这个实现,它永远不会进入goroutine。varmusync.Mutex//lengthis197Kfori:=0;i对于此使用waitGroups的实现,发生运行时内存不足varmusync.Mutexvarwgsync.WaitGroup//lengthis197Kfori:=0;i我不太确定发生了什么,需要一

go http.Request.Conn.ActiveConn是一个map,那么会不会有并发map的问题呢?

去http.Request.Context.ActiveConn是一个map,会不会有并发map问题?如果有很多连接,我打印包含ActiveConn(map)的request.Context,会不会有并发读写map的问题?packagemainimport("fmt""net/http")funcmain(){http.HandleFunc("/",func(whttp.ResponseWriter,r*http.Request){fmt.Fprintf(w,"r.ctx:%#v,%+v",r.Context(),r.Context())})http.ListenAndServe(":

concurrency - 为什么并发写入的boolean值设置为false后还是true?

我正在用Go编写哲学家用餐解决方案。我的解决方案很简单:检查两个fork是否可用。如果是这样,请同时选择两者。如果不是,请保留两者。但是,我遇到了一个奇怪的并发错误,即使在明确设置为false之后,fork的可用性仍然是true。我的Fork声明如下:typeForkstruct{musync.Mutexavailbool}func(f*Fork)PickUp()bool{f.mu.Lock()iff.avail==false{f.mu.Unlock()returnfalse}f.avail=falsefmt.Println("setfalse")f.mu.Unlock()return

go - 在 Go 中使用元编程解析网络协议(protocol)

在JavaScript(Node)中,我编写了一个模块,它接受一个字段列表及其类型,并返回一个带有pack和unpack方法的对象。下面是打包和解包IPv4的代码:varipv4=proto.add('struct',{name:'IPV4',fields:{version:'int:4',ihl:'int:4',dscp:'int:6',ecn:'int:2',length:'int:16',id:'int:16',flags:'int:3',offset:'int:13',ttl:'int:8',protocol:'int:8',checksum:'int:16',src:'IPV

concurrency - 使用并发的 Golang 流水线

Go新手。我正在尝试编写一个“流水线”,其中多个函数像worker一样工作,并在流水线中将一些数据结构传递给彼此,每个函数都对数据结构做一些事情。typeorderStructstruct{orderNum,capacityintorderCodeuint64box[9]int}funcposition0(inchanorderStruct){order:=>63==1){order.box[order.capacity]=1order.capacity+=1}fmt.Println("fillingbox{",order.orderNum,order.orderCode,order.

networking - 如何使用go编程语言在给定IP地址的情况下在网络上查找主机名

使用go编程语言,我能够找到给定主机名的IP地址,但我正在寻找的是找到给定ip地址的主机名。我尝试研究“net”包,但没有成功。这在golang中可行吗?请指教。 最佳答案 LookupAddr应该做你正在寻找的东西:LookupAddrperformsareverselookupforthegivenaddress,returningalistofnamesmappingtothataddress. 关于networking-如何使用go编程语言在给定IP地址的情况下在网络上查找主机名

go - golang 是否可以接受优雅的关闭写入并发模式?

我刚开始在go中使用并发。我有其他语言的并发经验,如果你试图写入一个封闭的channel,go会引发panic,这让我感到难过。这种模式会非常有用,因为您可以解耦参与者的生命周期并使它们独立。这使您不必同步清理它们。本质上,我可以让读取器在关闭之前关闭channel,并通知任意数量的写入器并通过channel上的写入错误停止阻塞(取消)。因此我编写了一个通用函数来处理这种形式的消息传递:///Sendsamessagetoaremotegeneralchannel.///Returnstrueifthemessagewassent(thesendstoppedblocking)orfa

Go 并发 : Chudnovky's algorithm, 比同步慢

最近在friend的推荐下开始学习围棋。到目前为止,我很喜欢它,但我写了(我认为会是)轻量级并发的完美示例,并得到了令人惊讶的结果......所以我怀疑我做错了什么,或者我是误解了goroutines的成本。我希望这里的一些gophers可以提供见解。我使用goroutines和简单的同步执行在Go中编写了Chudnovsky的算法。我假设,每个计算都独立于其他计算,同时运行至少会快一点。注意:我在第5代i7上运行它,所以如果goroutine像我被告知的那样被多路复用到线程上,这应该是并发的和并行的。packagemainimport("fmt""math""strconv""tim

Java网络编程 - 网络编程介绍 - 网络通信三要素

文章目录网络编程网络编程介绍网络通信三要素要素一:IP地址IP地址基本介绍IP地址的操作类要素二:端口号要素三:协议TCP协议UDP协议网络编程网络编程介绍什么是网络编程?网络编程可以让程序与网络上的其他设备中的程序进行数据交互。网络编程基本模式:常见的通信模式有如下2种形式:Client-Server(CS:客户端与服务器模式)、Browser/Server(BS:浏览器与服务器模式)Client-Server(CS)模式Browser/Server(BS)模式网络通信三要素实现网络编程关键的三要素:IP地址:设备在网络中的地址,是唯一的标识。端口:应用程序在设备中唯一的标识。协议:数据在网

尽管有锁,Go 仍检测到 map 上的并发读写

我正在编写一个简单的缓存机制,它有一个Add、一个Evict和一个Search方法。Search目前尚未实现,因此无需担心。调用Add添加数据的goroutine数量较多,只有一个goroutine运行在evict循环中逐出数据。一旦我对它施加一些严重的流量,Go就会抛出并说在mapmetricCache上有并发的读写访问,但我看不出这是怎么发生的,因为它周围有锁。我正在使用Go1.7。文件mdata/cache.go:57:funcNewCCache()*CCache{58:cc:=&CCache{59:lock:sync.RWMutex{},60:metricCache:make(